#ifndef _SERVER_PUSH_FLOW_H_
#define _SERVER_PUSH_FLOW_H_
#include "client_sock.h"
#include "cross_com.h"
class CServerPushFlow:public CClientSock
{
public:
	CServerPushFlow();
	~CServerPushFlow();

	int StartPushFlow();
	int StartReconnect();
	int VideoPushProc();
	static int PUB_THREAD_CALL PushFlowThread(void *pParam);
	static int PUB_THREAD_CALL ReconnectThread(void *pParam);
	
	void SetClientID(int clientID)
	{
		m_clientID = clientID;
	}

protected:
	cross_thread_t m_dataThdID;
	cross_thread_t m_reconnectThdID;
	uchar_t * m_frmBuf;
	int       m_bufSz;
	int      m_clientID;
	bool     m_connect_status;
	int      m_reconnect_tm;
};



#endif